//package com.rbac.web.mq.consumer;
//
//
//import com.google.gson.Gson;
//import com.rbac.web.model.res.UserGetOneRes;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.MessageModel;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
///**
// * @author gengaoliu
// * <p>consumerGroup消费者组，需要和messageModel共同使用，messageModel =
// * MessageModel.CLUSTERING则同一个消费者组中的所有消费者只能有一个消费者消费这一条消息； 如果messsageModel =
// * MessageModel.BROADCASTING,则同一个消费者组中的所有消费者中所有一个消费者都要消费这一条消息 所有消费者组中消费者messageModel =
// * MessageModel.CLUSTERING一致
// */
//@Slf4j
//@Component
//@RocketMQMessageListener(
//    topic = "send-user-msg",
//    selectorExpression = "*",
//    consumerGroup = "user-consumer",
//    messageModel = MessageModel.CLUSTERING)
//public class UserConsumer implements RocketMQListener<String> {
//
//  private final Gson gson;
//
//  public UserConsumer(Gson gson) {
//    this.gson = gson;
//  }
//
//  @Override
//  public void onMessage(String message) {
//    log.info("===============以下是消费信息===============");
//    log.info("===============以下是消费信息===============");
//    log.info("=========>接收到用户消息：{}", gson.fromJson(message, UserGetOneRes.class));
//  }
//}
